package com.hoveagle.kafka.consumer;

/**
 * define an interface for message kafka
 * @author hoveagle
 */
public interface MessageConsumer extends Runnable{
    void start();
    void stop();
}
